Aleph Git - /page/commit.mu

Micron Document

Aleph Git

Node / mirrors / interface_http / commits / 3df0ee2

Commit 3df0ee2fba689d2efb024b6fa0f3319ffd308466

󰉖 Browse tree at this commit

Parents : a2ad0df

Author : Ivan <ivan@quad4.io>

Date : 2025-09-26T17:50:50-05:00

Update data handling in Server class to accumulate and send multiple chunks from the send queue

Changes

1 files changed, 8 insertions(+), 5 deletions(-)

M http_interface.py +8 -5

Diff

diff --git a/http_interface.py b/http_interface.py

index d36b0cc..919dd6e 100644

--- a/http_interface.py

+++ b/http_interface.py

@@ -99,13 +99,16 @@ class Server(AbstractTunnel):

self.tunnel.logger.debug(f"Received {len(client_data)} bytes from client")

self.tunnel._recv_queue.put(client_data)

- server_data = b""

- if not self.tunnel._send_queue.empty():

+ server_data_parts = []

+ while not self.tunnel._send_queue.empty():

try:

- server_data = self.tunnel._send_queue.get_nowait()

- self.tunnel.logger.debug(f"Sending {len(server_data)} bytes to client")

+ server_data_parts.append(self.tunnel._send_queue.get_nowait())

except Empty:

- pass

+ break

+ server_data = b"".join(server_data_parts)

+ if server_data:

+ self.tunnel.logger.debug(f"Sending {len(server_data)} bytes ({len(server_data_parts)} chunks) to client")

self.send_response(200)

self.send_header('Content-Type', 'application/octet-stream')